package com.huaru.message.utile;

import com.alibaba.fastjson.JSONObject;
import com.glch.fkj398.msgservice.entity.TransferMsg;
import com.glch.fkj398.msgservice.handler.Message.MessengerService;

/**
 * Author: zx
 * Remark:发送信息
 * Time: 2023年6月7日10:30:01
 */
public class SendMessageUtil {

    public static void Send(JSONObject jsonObject, String ip){
        byte[] sendudp = jsonObject.toJSONString().getBytes();
        TransferMsg msg = new TransferMsg();
        //接收方IP地址 IP使用活的 不要写固定的动态获取
        msg.setIp(ip);
        /*udp端口*/
        msg.setPort(6947);
        //udp是否回包
        msg.setAck(1);
        //udp分包大小(不能大于65535)
        msg.setSubsectionsize(650);
        //超时重发次数
        msg.setRetrySendTimes(1);
        //超时时间
        msg.setTimeOutMS(1000);
        //发送的具体内容
        msg.setData(sendudp);
        MessengerService ms = new MessengerService();
        String send = null;
        //调用发送方法
        try {
            send = ms.SendUDP(msg);
            System.out.println(send+">>>>>>>");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
